# -*- coding: utf-8 -*-
from utils.operators.external_dag_sensor import ExternalDagSensorAsync
from datetime import timedelta

jms_dim__dim_network_whole_massage_ai_ageing_cusc_hi = ExternalDagSensorAsync(
    task_id='jms_dim__dim_network_whole_massage_ai_ageing_cusc_hi',
    external_dag_id='jms',
    external_task_id='jms_dim__dim_network_whole_massage',
    external_execution_date_time='{{ execution_date | hour_add(12) | date_add(-1) | cst_ds }} 00:15:00',
    execution_delta_time_unit='days',
    execution_delta=0,
    allowed_states='success',
    execution_timeout=timedelta(minutes=60),
    email='rongguangfan@jtexpress.com',
)


jms_dim__dim_lmdm_sys_area = ExternalDagSensorAsync(
    task_id='jms_dim__dim_lmdm_sys_area',
    external_dag_id='jms',
    external_task_id='jms_dim__dim_lmdm_sys_area',
    external_execution_date_time='{{ execution_date | hour_add(12) | date_add(-1) | cst_ds }} 00:15:00',
    execution_delta_time_unit='days',
    execution_delta=0,
    allowed_states='success',
    execution_timeout=timedelta(minutes=60),
    email='jarl.huang@jtexpress.com',
)
